//引入express模块
const express=require('express')
//引入连接池
const pool=require('../pool.js')
//console.log(pool)
//添加路由器
const router=express.Router()

/*****************开始写路由（接口）**********************/
//1.定义一个用户留言的接口
//请求方式：post
//请求地址：http://127.0.0.1:3000/v1/users/message
router.post('/message',(req,res,next)=>{
	var obj=req.body
	console.log(obj)
	//正则表达式验证用户输入的邮箱
	if(!/^\w+([-+.]\w+)*@\w+([-.]\w+)*\.\w+([-.]\w+)*$/.test(obj.email)){
		return res.send('邮箱格式错误')
	}
	//添加到数据库并响应消息
	pool.query('insert into message set ?',[obj],(err,r)=>{
		if(err){
			return next(err)
		}
		console.log(r)
		if(r.affectedRows===0){
			res.send({code:404,msg:'添加失败'})
		}else{
			res.send({code:200,msg:'添加成功'})
		}
	})
	
})


//暴露路由器
module.exports=router